import { RealtimeClient, SSEAdapter, WebSocketAdapter } from '../libs/index.js';
console.log('SSE 客户端启动');
// 初始化SSE客户端
const sseClient = new RealtimeClient(WebSocketAdapter, {
  url: 'ws://localhost:8081',
  retryInterval: 3000,
  format: 'json',
  events: ['custom-event']
});

// 监听服务端事件
sseClient.on('init', (data) => {
  console.log('初始化连接:', data.id);
});

sseClient.on('message', (data) => {
  console.log('接收到消息:', data);
});

sseClient.on('error', (err) => {
  console.error('连接异常:', err.message);
});

// 启动连接
sseClient.connect();

// 30秒后断开测试
setTimeout(() => {
  sseClient.disconnect();
  console.log('测试连接已主动断开');
}, 1000 * 60 * 10);